package sample.cluster.sample;

import akka.actor.UntypedActor;

/**
 * @author liuyi
 * @date 2017/03/08 17:49
 */
public class ExampleActor extends UntypedActor {

    @Override
    public void onReceive(Object message) throws Exception {
        if(message.equals("stop")){
            throw new IllegalStateException("manual throw exception!!!!!!!!!!!!!!!!");
        }
        System.out.println("111"+message);
    }
}
